public class LongValueAddOffset extends Object implements TranslateFunction<org.apache.flink.types.LongValue,org.apache.flink.types.LongValue>
LongValue by adding a constant offset value.| Constructor and Description |
|---|
LongValueAddOffset(long offset)
Translate
LongValue by adding a constant offset value. |
| Modifier and Type | Method and Description |
|---|---|
org.apache.flink.types.LongValue |
translate(org.apache.flink.types.LongValue value,
org.apache.flink.types.LongValue reuse)
The translating method.
|
public LongValueAddOffset(long offset)
LongValue by adding a constant offset value.
The summation is *not* checked for overflow or underflow.
offset - value to be added to each elementpublic org.apache.flink.types.LongValue translate(org.apache.flink.types.LongValue value,
org.apache.flink.types.LongValue reuse)
throws Exception
TranslateFunctiontranslate in interface TranslateFunction<org.apache.flink.types.LongValue,org.apache.flink.types.LongValue>value - input value.reuse - value which may be reused for output; if reuse is null then a new output object
must be instantiated and returnedException - This method may throw exceptions. Throwing an exception will cause the operation
to fail and may trigger recovery.Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.