public static class HiveSource.HiveSourceBuilder extends AbstractFileSource.AbstractFileSourceBuilder<RowData,HiveSourceSplit,HiveSource.HiveSourceBuilder>
continuousSourceSettings, fileEnumerator, inputPaths, readerFormat, splitAssigner
Modifier and Type | Method and Description |
---|---|
HiveSource |
build()
Creates the file source with the settings applied to this builder.
|
HiveSource.HiveSourceBuilder |
setFetcher(ContinuousPartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition,?> fetcher) |
HiveSource.HiveSourceBuilder |
setFetcherContext(HiveTableSource.HiveContinuousPartitionFetcherContext<?> fetcherContext) |
monitorContinuously, processStaticFileSet, setFileEnumerator, setSplitAssigner
public HiveSource build()
AbstractFileSource.AbstractFileSourceBuilder
build
in class AbstractFileSource.AbstractFileSourceBuilder<RowData,HiveSourceSplit,HiveSource.HiveSourceBuilder>
public HiveSource.HiveSourceBuilder setFetcher(ContinuousPartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition,?> fetcher)
public HiveSource.HiveSourceBuilder setFetcherContext(HiveTableSource.HiveContinuousPartitionFetcherContext<?> fetcherContext)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.