public interface DefinedProctimeAttribute
TableSource
.
The processing-time attribute can be used for indicating, accessing, and working with Flink's
processing-time.
A TableSource
that implements this interface defines the name of
the processing-time attribute. The attribute will be added to the schema of the
Table
produced by the TableSource
.
Modifier and Type | Method and Description |
---|---|
String |
getProctimeAttribute()
Defines a name of the processing-time attribute that represents Flink's
processing-time.
|
String getProctimeAttribute()
The field will be appended to the schema provided by the TableSource
.
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.