Tengo una ejecución de transmisión configurada como object FlinkSlidingEventTimeExample extends App { case class Trx(timestamp:Long, id:String, trx:String, count:Int) val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI() val watermarkS1 = WatermarkStrategy .forBoundedOutOfOrderness[Trx](Duration.ofSeconds(15)) .withTimestampAssigner(new SerializableTimestampAssigner[Trx] { override def extractTimestamp(element: Trx, recordTimestamp: Long): Long = element.timestamp }) val s1 = env.socketTextStream(“localhost”, 9999) .flatMap(l => l.split(” “)) .map(l . . . Read more
Tengo un marco de datos donde: df <- data.frame(position = c(1000,1156,3200,4629,5559,6100,7456,8208,9500,10000), col1 = c(0,0,1,1,1,0,0,1,1,0)) Si quisiera utilizar ventanas deslizantes de tamaño 2000, deslizándose cada 1000 (comenzando desde 1000 y terminando en 10000) basado en los valores de posición, ¿qué comando puedo usar para obtener el número de índice de la . . . Read more
Tengo una base de datos sqlite con múltiples filas en una tabla. Una de las columnas contiene cadenas con una cantidad arbitraria de enteros positivos, así que: 1: ‘### ## # # # ## # ##’ 2: ‘# ## # ## # ##’ 3: ‘# # # ## ## ### . . . Read more
Mi pregunta es sobre cómo calcular los datos de cotización en DolphinDB. La tabla contiene cuatro columnas (ticker, fecha, cierre y volumen) y está agrupada por ticker y ordenada por fecha. Quiero hacer un cálculo de ventana y supongo que el tamaño de la ventana es de 20. Mi objetivo . . . Read more
Tengo un conjunto de datos en el que: df <- data.frame(row_id = c(100, 101, 102, 103, 104, 105, 106, 107, 108, 109), row_id2 = c(1000,2000,3000,4000,5000,6000,7000,8000,9000,10000), col1 = c(1,0,1,1,1,0,0,1,1,0), col2 = c(1,1,1,0,0,1,1,1,0,0), col3 = c(0,0,1,0,0,1,1,1,1,0), col4 = c(1,1,1,0,0,1,0,1,1,1), col5 = c(1,1,1,0,1,0,1,0,0,1)) Tengo que transponer la tabla y luego agregar una nueva . . . Read more