public class TimePartitionedDataPublisherWithFlag extends TimePartitionedDataPublisher
Modifier and Type | Field and Description |
---|---|
protected TimePartitionedFlagDataPublisher |
flagPublisher |
closer, lineageInfo, metadataMergers, metaDataWriterFileSystemByBranches, numBranches, parallelRunnerCloser, parallelRunners, parallelRunnerThreads, permissions, publisherFileSystemByBranches, publisherFinalDirOwnerGroupsByBranches, publisherOutputDirs, retrierConfig, shouldRetry, writerFileSystemByBranches
Constructor and Description |
---|
TimePartitionedDataPublisherWithFlag(org.apache.gobblin.configuration.State state) |
Modifier and Type | Method and Description |
---|---|
void |
publish(Collection<? extends org.apache.gobblin.configuration.WorkUnitState> states) |
addWriterOutputToExistingDir, addWriterOutputToNewDir
addSingleTaskWriterOutputToExistingDir, close, createDestinationDescriptor, getPublisherOutputDir, initialize, movePath, publishData, publishData, publishData, publishMetadata, publishMetadata, publishMultiTaskData, recordPublisherOutputDirs, shouldPublishMetadataFirst
getInstance, publish
protected final TimePartitionedFlagDataPublisher flagPublisher
public TimePartitionedDataPublisherWithFlag(org.apache.gobblin.configuration.State state) throws IOException
IOException
public void publish(Collection<? extends org.apache.gobblin.configuration.WorkUnitState> states) throws IOException
publish
in class org.apache.gobblin.publisher.DataPublisher
IOException
Copyright © 2021. All rights reserved.