Setting BigTable cell timestamp gives an error
@@ -26,6 +26,7 @@ import org.apache.beam.sdk.values.KV;
import org.apache.hop.beam.core.BeamHop;
import org.apache.hop.beam.core.HopRow;
import org.apache.hop.beam.core.util.JsonRowMeta;
+import org.apache.hop.core.exception.HopException;
import org.apache.hop.core.row.IRowMeta;
import org.apache.hop.core.row.IValueMeta;
import org.apache.hop.pipeline.Pipeline;
@@ -133,7 +134,7 @@ public class HopToBigtableFn extends DoFn<HopRow, KV<ByteString, Iterable<Mutati
Mutation.SetCell.newBuilder()
.setFamilyName(column.getFamily())
.setColumnQualifier(toByteString(column.getName()))
- .setTimestampMicros(System.currentTimeMillis())
+ .setTimestampMicros(System.currentTimeMillis()*1000)
.setValue(toByteString(valueMeta, valueData))
.build();
Mutation mutation = Mutation.newBuilder().setSetCell(setCell).build();
