com.xxdb.streaming.client.streamingSQL

Class StreamingSQLResultUpdater

java.lang.Object

com.xxdb.streaming.client.streamingSQL.StreamingSQLResultUpdater

public class StreamingSQLResultUpdater
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	StreamingSQLResultUpdater.StreamingSQLResult Streaming SQL result wrapper class, containing table and row number mapping

Constructor Summary

Constructors

Constructor and Description
StreamingSQLResultUpdater()

Method Summary

Modifier and Type	Method and Description
protected static StreamingSQLResultUpdater.StreamingSQLResult	updateStreamingSQLResult(BasicTable result, BasicIntVector deleteLineMap, IMessage msg) Update streaming SQL result table

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamingSQLResultUpdater

public StreamingSQLResultUpdater()

Method Detail

updateStreamingSQLResult

protected static StreamingSQLResultUpdater.StreamingSQLResult updateStreamingSQLResult(BasicTable result,
                                                                                       BasicIntVector deleteLineMap,
                                                                                       IMessage msg)
                                                                                throws Exception

Update streaming SQL result table

Parameters:

result - The result table to update

deleteLineMap - Row number mapping

msg - Log message

Returns:

Result object containing updated table and row number mapping

Throws:

Exception - If an error occurs during update