public class OSSTaskConfig extends Object
构造器和说明 |
---|
OSSTaskConfig()
初始化OSSTaskConfig实例
|
限定符和类型 | 方法和说明 |
---|---|
void |
addParquetSchema(ParquetSchema parquetSchema)
添加数据投递列
|
EventColumn |
getEventTimeColumn()
获取事件时间列名
|
OSSFileFormat |
getFormat()
获取投递OSS上文件格式,目前仅支持parquet格式
|
String |
getOssBucket()
获取OSS Bucket
|
String |
getOssEndpoint()
获取OSS endpoint
|
String |
getOssPrefix()
获取OSS路径前缀
|
String |
getOssStsRole()
获取StsRole
|
List<ParquetSchema> |
getParquetSchemaList()
获取投递任务Schema
|
TimeFormatter |
getTimeFormatter()
获取投递OSS分区格式,目前仅支持年月日格式
|
void |
setEventTimeColumn(EventColumn eventTimeColumn)
设置事件时间列名
|
void |
setFormat(OSSFileFormat format)
设置投递OSS上文件格式
|
void |
setOssBucket(String ossBucket)
设置OSS Bucket
|
void |
setOssEndpoint(String ossEndpoint)
设置OSS endpoint
|
void |
setOssPrefix(String ossPrefix)
设置OSS路径前缀
|
void |
setOssStsRole(String ossStsRole)
设置StsRole
|
void |
setTimeFormatter(TimeFormatter timeFormatter)
设置投递OSS分区格式
|
String |
toString() |
public String getOssPrefix()
public void setOssPrefix(String ossPrefix)
ossPrefix
- OSS路径前缀public TimeFormatter getTimeFormatter()
public void setTimeFormatter(TimeFormatter timeFormatter)
timeFormatter
- 投递OSS分区格式public String getOssBucket()
public void setOssBucket(String ossBucket)
ossBucket
- OSS Bucketpublic String getOssEndpoint()
public void setOssEndpoint(String ossEndpoint)
ossEndpoint
- OSS endpointpublic String getOssStsRole()
public void setOssStsRole(String ossStsRole)
ossStsRole
- StsRolepublic EventColumn getEventTimeColumn()
public void setEventTimeColumn(EventColumn eventTimeColumn)
eventTimeColumn
- 事件时间列名public OSSFileFormat getFormat()
public void setFormat(OSSFileFormat format)
format
- public List<ParquetSchema> getParquetSchemaList()
public void addParquetSchema(ParquetSchema parquetSchema)
parquetSchema
- Copyright © 2021. All Rights Reserved.