StreamTransformation object

[AndreaKinn]

Hi,
I'm using an external library with Flink I'm trying to implement
slotSharingGroup(String) method on it.
To do it I looked at SingleOutputStreamOperator Flink's class to see how the
method slotSharingGroup(String) is implemented.

An abstract:

/public class SingleOutputStreamOperator<T> extends DataStream<T> {

SingleOutputStreamOperator(StreamExecutionEnvironment environment,
StreamTransformation<T> transformation) {
                super(environment, transformation);
        }

SingleOutputStreamOperator<T> slotSharingGroup(String slotSharingGroup) {
                transformation.setSlotSharingGroup(slotSharingGroup);
                return this;
        }
}/

so I changed the constructor of external library class which has to offer
the slotSharingGroup() method making it more adherent to
SingleOutputStreamOperator template.

Now my problem is how to call it (see below) because I don't understand what
is StreamTransformation<T> object among the parameters of the constructor of
SingleOutputStreamOperator and how to obtain it in main class.

Following the method I call:

/DataStream<Tuple7&lt;String, String, Date, String, String, Double, Double>>
LCxAccResult = HTM.learn(env, */* what STREAMTRANSFORMATION<T> here?
*/*).slotSharingGroup("group");
/

Hope you can help me, thanks in advance
Andrea



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/