How to connect to Velocity Analytics 8 using API

I tried connecting to Velocity Analytics 8, but an error occurred in the middle process.

ClassCastException is output with the following method.
DeltaQRoundRobinConnectionFactory.loadHostListFromCurrentConnection ()

The processing flow is as follows.

Generate DefaultDeltaStream
Run InitialiseDeltaControl()
A log of DeltaCConnectorThread is output and a message of Connection thread completed is output.
It ends immediately with ClassCastException.

Find more posts tagged with

java

api

velocity-analytics

Accepted answers

Pavel.Hurynovich

Hello Yokoyama Ryouta,

To connect to the GW process you can use Java driver from Kx Systems. It's an interface for kdb+, check link below:

https://code.kx.com/q/interfaces/java-client-for-q/

You need to use c.java class, create connection to your gateway and send query as sync message. Example:

c c=null; //connection object
c=new c("host",5010,"username:password"); //create connection
Object result=c.k("your query here"); //send a sync message and 
recieve resultc.Flip flip = c.td(result); //convert result object to 
c.Flip

All comments

Pavel.Hurynovich

Hello Yokoyama Ryouta,

As I understand you trying to pass incorrect object instance to DeltaStream.initialiseDeltaControl() method:

https://docs.oracle.com/javase/1.5.0/docs/api/java/lang/ClassCastException.html

InitialiseDeltaControl signatures:

void initialiseDeltaControl(ConfigurationManager var1); 

void initialiseDeltaControl(ConfigurationManager var1, String var2); 

void initialiseDeltaControl(String var1, int var2, String var3, int var4, String var5, int var6, boolean var7, String var8, int var9, int var10, boolean var11) throws DeltaStreamException; 

void initialiseDeltaControl(String var1, Integer var2, String var3, Integer var4, String var5, Integer var6, Boolean var7, String var8, Integer var9, Integer var10, Boolean var11, Boolean var12) throws DeltaStreamException;

Example of InitialiseDeltaControl call:

deltaStream.initialiseDeltaControl(primaryHost, primaryPort.intValue(), secondaryHost, secondaryPort.intValue(),instanceName, instanceId.intValue(), exclusive.booleanValue(), loginString,retryMaxTimeOutPeriod.intValue(), retryTimeoutStep.intValue(), encrypted.booleanValue());

note that host parameters should be passed as String objects, port - as Int.

Hope this helps.

yokoyama

Hello Hurynovich,

Thank you for your response.

I understood that an exception occurred in initialiseDeltaControl.
I reconfirmed the call of initialiseDeltaControl, but I have not found a problem.
I am coding as follows, but where is the problem?
Note: IP, ID and PW are masked.

private DeltaStream createStream() throws DeltaStreamException {
    DeltaStream stream = DeltaStreamFactory.newDeltaStream();
    stream.initialiseDeltaControl(
        "XX.XX.XX.XX.", //primaryhost
        1234,//primaryport
        null,//secondaryhost
        0,//secondaryport
        "Develop",//instancename
        0,//instanceId
        true,//exclusive
        "XXXXXXX:XXXX",//loginString
        10000,//retryMaxTimeOutPeriod
        1000,//retryTimeoutStep
        false //encrypted
    );

Pavel.Hurynovich

Hello Yokoyama Ryouta,

Code looks right, can you please recheck is "stream" object an instance of DefaultDeltaStream and all values passed into initialiseDeltaControl method have right types? Also which version of VA binaries you use? I've tested this code and it works

yokoyama

Hello Hurynovich,
thank you so much for your reply.
I may be making a misunderstanding.
When executing the q command using the Delta IDE, I am connected to the Gateway process.
For this reason, I thought that the VA8 Java API will connect to the Gateway process as well, but is this understanding wrong?
If you designate the destination Port as a DeltaControl process, ClassCastException no longer occurs.

Pavel.Hurynovich

Hello Yokoyama Ryouta,

You are welcome! That's right - VA8 C#/Java API should be connected to main DC port (same port using for connection to your VA instance in DeltaControl application).

yokoyama

Hello Hurynovich,
Thanks to your answer, I was able to correct my wrong understanding.
By the way, do you know how to connect to the Gateway process using Java and get data?

Pavel.Hurynovich

c c=null; //connection object
c=new c("host",5010,"username:password"); //create connection
Object result=c.k("your query here"); //send a sync message and 
recieve resultc.Flip flip = c.td(result); //convert result object to 
c.Flip

yokoyama

Hello Hurynovich,
I was able to connect to the Gateway process and retrieve the data.
I greatly appreciate your help.

EXPLORE OUR SITES