Package | Description |
---|---|
org.apache.flink.connectors.hive | |
org.apache.flink.table.filesystem | |
org.apache.flink.table.filesystem.stream |
Modifier and Type | Class and Description |
---|---|
class |
HadoopFileSystemFactory
Hive
FileSystemFactory , hive need use job conf to create file system. |
Modifier and Type | Method and Description |
---|---|
static DataStreamSink<RowData> |
FileSystemTableSink.createStreamingSink(Configuration conf,
Path path,
List<String> partitionKeys,
ObjectIdentifier tableIdentifier,
boolean overwrite,
DataStream<RowData> inputStream,
StreamingFileSink.BucketsBuilder<RowData,String,? extends StreamingFileSink.BucketsBuilder<RowData,?,?>> bucketsBuilder,
TableMetaStoreFactory msFactory,
FileSystemFactory fsFactory,
long rollingCheckInterval) |
FileSystemOutputFormat.Builder<T> |
FileSystemOutputFormat.Builder.setFileSystemFactory(FileSystemFactory fileSystemFactory) |
Constructor and Description |
---|
StreamingFileCommitter(Path locationPath,
ObjectIdentifier tableIdentifier,
List<String> partitionKeys,
TableMetaStoreFactory metaStoreFactory,
FileSystemFactory fsFactory,
Configuration conf) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.