Create

create table tt (dts timestamp, nts timestamp) timestamp(dts)

Insert

insert into tt 
select timestamp_sequence(1577836800000000L, 10L), timestamp_sequence(1577836800000000L, 10L) 
from long_sequence(2L)

Select

select 'nts', min(nts) from tt where nts > '2020-01-01T00:00:00.000000Z'

Expected
nts in the first column

Actual
timestamp

For example, given a simple pipeline such as:

Pipeline p = Pipeline.create();
p.readFrom(TestSources.items("the", "quick", "brown", "fox"))
 .aggregate(aggregator)
 .writeTo(Sinks.logger());

I'd like aggregator to be something requiring a non-serialisable dependency to do its work.

I know I can do this:

Pipeline p = Pipeline.create();
p.readFrom(TestSource