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 Resolvablepublic java.lang.Class<? extends BaseDataType> getType()
getType in interface Resolvablevoid setDatum(BaseDataType datum)
datum - Current data value.