TaskPublisher function ( TaskState arg0 , TaskLevelPolicyCheckResults arg1 ) { return TaskPublisherBuilderFactory . newTaskPublisherBuilder ( arg0 , arg1 ) . build ( ) ; }
get a post-fork taskpublisher for publishing data in the given branch . concode_field_sep TaskState taskState concode_elem_sep Extractor rawSourceExtractor concode_elem_sep TaskMetrics taskMetrics concode_field_sep Destination.DestinationType getDestinationType concode_elem_sep Extractor getRawSourceExtractor concode_elem_sep List<Converter<?,?,?,?>> getConverters concode_elem_sep List<Converter<?,?,?,?>> getConverters concode_elem_sep WatermarkStorage getWatermarkStorage concode_elem_sep RowLevelPolicyChecker getRowLevelPolicyChecker concode_elem_sep RowLevelPolicyChecker getRowLevelPolicyChecker concode_elem_sep ForkOperator getForkOperator concode_elem_sep DataWriterBuilder getDataWriterBuilder concode_elem_sep long getStatusReportingInterval concode_elem_sep TaskMetrics getTaskMetrics concode_elem_sep TaskLevelPolicyChecker getTaskLevelPolicyChecker concode_elem_sep Extractor getExtractor concode_elem_sep Source getSource concode_elem_sep TaskState getTaskState concode_elem_sep WriterOutputFormat getWriterOutputFormat