public static class FlowProcess.NullFlowProcess extends FlowProcess<Object>
FlowProcess.NullFlowProcessNULL| Modifier | Constructor and Description |
|---|---|
protected |
FlowProcess.NullFlowProcess() |
| Modifier and Type | Method and Description |
|---|---|
Object |
copyConfig(Object config) |
FlowProcess |
copyWith(Object object) |
Map<String,String> |
diffConfigIntoMap(Object defaultConfig,
Object updatedConfig) |
Object |
getConfig()
Method getConfig returns the actual instance of the underlying configuration instance.
|
Object |
getConfigCopy() |
long |
getCounterValue(Enum counter)
Method getCounterValue is used to retrieve a counter value.
|
long |
getCounterValue(String group,
String counter)
Method getCounterValue is used to retrieve a counter value.
|
int |
getCurrentSliceNum()
Method getCurrentSliceNum returns an integer representing which slice instance currently running.
|
int |
getNumProcessSlices()
Method getNumProcessSlices returns the number of parallel slices or tasks allocated
for this process execution.
|
Object |
getProperty(String key)
Method getProperty should be used to return configuration parameters from the underlying system.
|
Collection<String> |
getPropertyKeys()
Method getPropertyKeys returns an immutable collection of all available property key values.
|
void |
increment(Enum counter,
long amount)
Method increment is used to increment a custom counter.
|
void |
increment(String group,
String counter,
long amount)
Method increment is used to increment a custom counter.
|
boolean |
isCounterStatusInitialized()
Method isCounterStatusInitialized returns true if it is safe to increment a counter or set a status.
|
void |
keepAlive()
Method keepAlive notifies the system that the current process is still alive.
|
Object |
mergeMapIntoConfig(Object defaultConfig,
Map<String,String> map) |
Object |
newInstance(String className)
Method newInstance creates a new object instance from the given className argument delegating to any
platform specific instantiation and configuration routines.
|
TupleEntryCollector |
openSystemIntermediateForWrite() |
TupleEntryIterator |
openTapForRead(Tap tap)
Method openTapForRead return a
TupleEntryIterator for the given Tap instance. |
TupleEntryCollector |
openTapForWrite(Tap tap)
Method openTapForWrite returns a (@link TupleCollector} for the given Tap instance.
|
TupleEntryCollector |
openTrapForWrite(Tap trap)
Method openTrapForWrite returns a (@link TupleCollector} for the given Tap instance.
|
void |
setStatus(String status)
Method setStatus is used to set the status of the current operation.
|
closeTrapCollectors, getBooleanProperty, getBooleanProperty, getCurrentSession, getID, getIntegerProperty, getIntegerProperty, getStringProperty, getStringProperty, getTrapCollectorFor, getTrapCollectors, setCurrentSessionprotected FlowProcess.NullFlowProcess()
public FlowProcess copyWith(Object object)
copyWith in class FlowProcess<Object>public Object getProperty(String key)
FlowProcessgetProperty in class FlowProcess<Object>key - of type Stringpublic Collection<String> getPropertyKeys()
FlowProcessgetPropertyKeys in class FlowProcess<Object>public Object newInstance(String className)
FlowProcessnewInstance in class FlowProcess<Object>public void keepAlive()
FlowProcessOperation takes some moments to complete. Each system is different, so calling
ping every few seconds to every minute or so would be best.
This method will fail silently if the underlying mechanism to notify keepAlive status are not initialized.keepAlive in class FlowProcess<Object>public void increment(Enum counter, long amount)
FlowProcessFlowProcess.isCounterStatusInitialized().increment in class FlowProcess<Object>counter - of type Enumamount - of type intpublic void increment(String group, String counter, long amount)
FlowProcessFlowProcess.isCounterStatusInitialized().increment in class FlowProcess<Object>group - of type Stringcounter - of type Stringamount - of type intpublic long getCounterValue(Enum counter)
FlowProcessFlowProcess.isCounterStatusInitialized().getCounterValue in class FlowProcess<Object>counter - of type Enumpublic long getCounterValue(String group, String counter)
FlowProcessFlowProcess.isCounterStatusInitialized().getCounterValue in class FlowProcess<Object>group - of type Stringcounter - of type Stringpublic void setStatus(String status)
FlowProcessFlowProcess.isCounterStatusInitialized().setStatus in class FlowProcess<Object>status - of type Stringpublic boolean isCounterStatusInitialized()
FlowProcessisCounterStatusInitialized in class FlowProcess<Object>public int getNumProcessSlices()
FlowProcessgetNumProcessSlices in class FlowProcess<Object>public int getCurrentSliceNum()
FlowProcess0 (zero) is the first slice instance.getCurrentSliceNum in class FlowProcess<Object>public TupleEntryIterator openTapForRead(Tap tap) throws IOException
FlowProcessTupleEntryIterator for the given Tap instance.
Note the returned iterator will return the same instance of TupleEntry on every call,
thus a copy must be made of either the TupleEntry or the underlying Tuple instance if they are to be
stored in a Collection.openTapForRead in class FlowProcess<Object>tap - of type TapIOException - when there is a failure opening the resourcepublic TupleEntryCollector openTapForWrite(Tap tap) throws IOException
FlowProcessopenTapForWrite in class FlowProcess<Object>tap - of type TapIOException - when there is a failure opening the resourcepublic TupleEntryCollector openTrapForWrite(Tap trap) throws IOException
FlowProcessopenTrapForWrite in class FlowProcess<Object>trap - of type TapIOException - when there is a failure opening the resourcepublic TupleEntryCollector openSystemIntermediateForWrite() throws IOException
openSystemIntermediateForWrite in class FlowProcess<Object>IOExceptionpublic Object getConfig()
FlowProcessFlowProcess.getConfigCopy() for a modifiable instance.getConfig in class FlowProcess<Object>public Object getConfigCopy()
getConfigCopy in class FlowProcess<Object>public Object copyConfig(Object config)
copyConfig in class FlowProcess<Object>public Map<String,String> diffConfigIntoMap(Object defaultConfig, Object updatedConfig)
diffConfigIntoMap in class FlowProcess<Object>public Object mergeMapIntoConfig(Object defaultConfig, Map<String,String> map)
mergeMapIntoConfig in class FlowProcess<Object>Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.