@Test
public void should_execute_statement_with_timestamp_option() throws Exception {

    //Given
    String statement1 = "INSERT INTO zeppelin.ts(key,val) VALUES('k','v1');";
    String statement2 = "@timestamp=15\n" +
            "INSERT INTO zeppelin.ts(key,val) VALUES('k','v2');";
    // Insert v1 with current timestamp
    interpreter.interpret(statement1, intrContext);
    Thread.sleep(1);
    //When
    // Insert v2 with past timestamp
    interpreter.interpret(statement2, intrContext);
    final String actual = session.execute("SELECT * FROM zeppelin.ts LIMIT 1").one().getString("val");
    //Then
    assertThat(actual).isEqualTo("v1");
}