@Override
    public void onPipelineEventOverLink(PipelineEvent<double[]> arg0,
            PipelineParameters arg1) {

        Log.d("DbaTransformer","samplingvalue");
        mSampler.onSamplingValue(arg0.timestamp, arg0.value);

        if(publishMergedResult){
            Log.d("DbaTransformer","zwei");
            PipelineEvent<double[]> pe;
            int i              = 0;
            long durationStep  = mergedResultDuration / mergedResult.length;  // calculate time-difference between values
            for(double[] moment : mergedResult){
                Log.d("DbaTransformer","pushed! "+i);
                pe = new PipelineEvent<double[]>(arg0.source,(arg0.timestamp + i), moment);
                this.nextComponent.onPipelineEventOverLink(pe, arg1 );
                i += durationStep;
            }
            remote.reset();
            publishMergedResult  = false;
        }


    }