public class LocalFlowProcess extends FlowProcess<Properties>
FlowProcess
.FlowProcess.NullFlowProcess
NULL
Constructor and Description |
---|
LocalFlowProcess() |
LocalFlowProcess(FlowSession flowSession,
Properties config) |
LocalFlowProcess(LocalFlowProcess flowProcess,
Properties properties) |
LocalFlowProcess(Properties config) |
Modifier and Type | Method and Description |
---|---|
<C> C |
copyConfig(C config) |
FlowProcess |
copyWith(Properties object) |
<C> Map<String,String> |
diffConfigIntoMap(C defaultConfig,
C updatedConfig) |
Properties |
getConfig() |
Properties |
getConfigCopy() |
long |
getCounterValue(Enum counter) |
long |
getCounterValue(String group,
String counter) |
int |
getCurrentSliceNum() |
int |
getNumProcessSlices() |
Object |
getProperty(String key) |
Collection<String> |
getPropertyKeys() |
void |
increment(Enum counter,
long amount) |
void |
increment(String group,
String counter,
long amount) |
boolean |
isCounterStatusInitialized() |
void |
keepAlive() |
Properties |
mergeMapIntoConfig(Properties defaultConfig,
Map<String,String> map) |
Object |
newInstance(String className) |
TupleEntryCollector |
openSystemIntermediateForWrite() |
TupleEntryIterator |
openTapForRead(Tap tap) |
TupleEntryCollector |
openTapForWrite(Tap tap) |
TupleEntryCollector |
openTrapForWrite(Tap trap) |
void |
setStatus(String status) |
void |
setStepStats(LocalStepStats stepStats) |
closeTrapCollectors, getBooleanProperty, getBooleanProperty, getCurrentSession, getID, getIntegerProperty, getIntegerProperty, getStringProperty, getStringProperty, getTrapCollectorFor, getTrapCollectors, setCurrentSession
public LocalFlowProcess()
public LocalFlowProcess(Properties config)
public LocalFlowProcess(FlowSession flowSession, Properties config)
public LocalFlowProcess(LocalFlowProcess flowProcess, Properties properties)
public void setStepStats(LocalStepStats stepStats)
public int getNumProcessSlices()
getNumProcessSlices
in class FlowProcess<Properties>
public int getCurrentSliceNum()
getCurrentSliceNum
in class FlowProcess<Properties>
public Object getProperty(String key)
getProperty
in class FlowProcess<Properties>
public Collection<String> getPropertyKeys()
getPropertyKeys
in class FlowProcess<Properties>
public Object newInstance(String className)
newInstance
in class FlowProcess<Properties>
public void keepAlive()
keepAlive
in class FlowProcess<Properties>
public void increment(Enum counter, long amount)
increment
in class FlowProcess<Properties>
public void increment(String group, String counter, long amount)
increment
in class FlowProcess<Properties>
public long getCounterValue(Enum counter)
getCounterValue
in class FlowProcess<Properties>
public long getCounterValue(String group, String counter)
getCounterValue
in class FlowProcess<Properties>
public void setStatus(String status)
setStatus
in class FlowProcess<Properties>
public boolean isCounterStatusInitialized()
isCounterStatusInitialized
in class FlowProcess<Properties>
public TupleEntryIterator openTapForRead(Tap tap) throws IOException
openTapForRead
in class FlowProcess<Properties>
IOException
public TupleEntryCollector openTapForWrite(Tap tap) throws IOException
openTapForWrite
in class FlowProcess<Properties>
IOException
public TupleEntryCollector openTrapForWrite(Tap trap) throws IOException
openTrapForWrite
in class FlowProcess<Properties>
IOException
public TupleEntryCollector openSystemIntermediateForWrite() throws IOException
openSystemIntermediateForWrite
in class FlowProcess<Properties>
IOException
public FlowProcess copyWith(Properties object)
copyWith
in class FlowProcess<Properties>
public Properties getConfig()
getConfig
in class FlowProcess<Properties>
public Properties getConfigCopy()
getConfigCopy
in class FlowProcess<Properties>
public <C> C copyConfig(C config)
copyConfig
in class FlowProcess<Properties>
public <C> Map<String,String> diffConfigIntoMap(C defaultConfig, C updatedConfig)
diffConfigIntoMap
in class FlowProcess<Properties>
public Properties mergeMapIntoConfig(Properties defaultConfig, Map<String,String> map)
mergeMapIntoConfig
in class FlowProcess<Properties>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.