private static class Accumulator.ExternalDataSource extends java.lang.Object implements Resolvable
Modifier and Type | Field and Description |
---|---|
private BaseDataType |
datum
Current data value
|
private java.lang.Class<? extends BaseDataType> |
type
The type of this source.
|
Modifier | Constructor and Description |
---|---|
private |
ExternalDataSource()
Default c'tor.
|
private |
ExternalDataSource(java.lang.Class<? extends BaseDataType> cls)
This c'tor must provide the type of the values being accumulated.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Class<? extends BaseDataType> |
getType()
Get the type of the current datum.
|
BaseDataType |
resolve()
Get the current data value.
|
(package private) void |
setDatum(BaseDataType datum)
Set the current data value, supplied by an external source.
|
private BaseDataType datum
private java.lang.Class<? extends BaseDataType> type
private ExternalDataSource()
private ExternalDataSource(java.lang.Class<? extends BaseDataType> cls)
cls
- Data type of the value being accumulated.public BaseDataType resolve()
resolve
in interface Resolvable
public java.lang.Class<? extends BaseDataType> getType()
getType
in interface Resolvable
void setDatum(BaseDataType datum)
datum
- Current data value.