You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@phoenix.apache.org by siddhimehta <gi...@git.apache.org> on 2015/07/10 08:13:00 UTC

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

GitHub user siddhimehta opened a pull request:

    https://github.com/apache/phoenix/pull/98

    PHOENIX-2098 - Udf that given a number bulk reserves sequences.

    

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/siddhimehta/phoenix master

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/phoenix/pull/98.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #98
    
----
commit 7ec6bbad40b0c9cbe61ff099f910fb85144029e6
Author: Siddhi <sm...@salesforce.com>
Date:   2015-07-06T23:26:55Z

    PHOENIX-2098 - Udf that given a number bulk reserves sequences.

----


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by JamesRTaylor <gi...@git.apache.org>.
Github user JamesRTaylor commented on the pull request:

    https://github.com/apache/phoenix/pull/98#issuecomment-120245488
  
    Looks very good, @siddhimehta. Thanks for the quick turnaround. Couple of minor nits and then I'll commit it on your behalf.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by JamesRTaylor <gi...@git.apache.org>.
Github user JamesRTaylor commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34330056
  
    --- Diff: phoenix-pig/src/it/java/org/apache/phoenix/pig/udf/ReserveNSequenceTestIT.java ---
    @@ -0,0 +1,284 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +import static org.apache.phoenix.query.BaseTest.setUpConfigForMiniCluster;
    +import static org.junit.Assert.assertEquals;
    +import static org.junit.Assert.assertTrue;
    +
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.DriverManager;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +import java.util.Properties;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HBaseTestingUtility;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.end2end.NeedsOwnMiniClusterTest;
    +import org.apache.phoenix.jdbc.PhoenixDriver;
    +import org.apache.phoenix.util.PhoenixRuntime;
    +import org.apache.phoenix.util.PropertiesUtil;
    +import org.apache.phoenix.util.TestUtil;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.data.TupleFactory;
    +import org.apache.pig.impl.util.UDFContext;
    +import org.junit.After;
    +import org.junit.AfterClass;
    +import org.junit.Before;
    +import org.junit.BeforeClass;
    +import org.junit.Rule;
    +import org.junit.Test;
    +import org.junit.experimental.categories.Category;
    +import org.junit.rules.ExpectedException;
    +
    +/**
    + * Test class to run all the Pig Sequence UDF integration tests against a virtual map reduce cluster.
    + */
    +@Category(NeedsOwnMiniClusterTest.class)
    +public class ReserveNSequenceTestIT {
    --- End diff --
    
    Minor item: please take at Ravi's latest changes for BaseHBaseManagedTimeIT [here](https://git-wip-us.apache.org/repos/asf?p=phoenix.git;a=commit;h=984e62223c8aa507e9c044cecfc7fc92ffa42522). It'd be good if you did that as well - it's easier to manage tests that derive from our base classes as the framework changes. Also, they run faster if you don't need to spin up your own cluster for each test.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by siddhimehta <gi...@git.apache.org>.
Github user siddhimehta commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34334715
  
    --- Diff: phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java ---
    @@ -0,0 +1,88 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
    + * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
    + * to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
    + * License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by
    + * applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language
    + * governing permissions and limitations under the License.
    + */
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.mapreduce.util.ConnectionUtil;
    +import org.apache.pig.EvalFunc;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.impl.util.UDFContext;
    +
    +import com.google.common.base.Preconditions;
    +
    +/**
    + * UDF to Reserve a chunk of numbers for a given sequence
    + * 
    + * @note The way this UDF is invoked we open a new connection for every tuple row. The UDF will not perform well on
    --- End diff --
    
    @JamesRTaylor I corrected the nits. 
    @anilgupta84 I can investigate more to see if its possible to pass in the connection object to the UDF. If  we make can make Connection an instance variable of UDF class how do we ensure that the connection is correctly released/closed after all the rows. 


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by anilgupta84 <gi...@git.apache.org>.
Github user anilgupta84 commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34331815
  
    --- Diff: phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java ---
    @@ -0,0 +1,88 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
    + * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
    + * to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
    + * License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by
    + * applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language
    + * governing permissions and limitations under the License.
    + */
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.mapreduce.util.ConnectionUtil;
    +import org.apache.pig.EvalFunc;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.impl.util.UDFContext;
    +
    +import com.google.common.base.Preconditions;
    +
    +/**
    + * UDF to Reserve a chunk of numbers for a given sequence
    + * 
    + * @note The way this UDF is invoked we open a new connection for every tuple row. The UDF will not perform well on
    --- End diff --
    
    I am not an expert at Pig or its UDF's. 
    Isnt there anyway to pass Connection object in UDF rather than creating it for every row? If you cant pass Connection, can you make Connection an instance variable of UDF class?
    Is creating new connection only reason for its non-scalability?
    @JamesRTaylor Do you think, this non-scalability might lead to bad user experience in production clusters?


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by anilgupta84 <gi...@git.apache.org>.
Github user anilgupta84 commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34333325
  
    --- Diff: phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java ---
    @@ -0,0 +1,88 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
    + * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
    + * to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
    + * License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by
    + * applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language
    + * governing permissions and limitations under the License.
    + */
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.mapreduce.util.ConnectionUtil;
    +import org.apache.pig.EvalFunc;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.impl.util.UDFContext;
    +
    +import com.google.common.base.Preconditions;
    +
    +/**
    + * UDF to Reserve a chunk of numbers for a given sequence
    + * 
    + * @note The way this UDF is invoked we open a new connection for every tuple row. The UDF will not perform well on
    --- End diff --
    
    i c.. In that case, this UDF is scalable? Or It is non-scalable due to some other reason?


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by JamesRTaylor <gi...@git.apache.org>.
Github user JamesRTaylor commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34333599
  
    --- Diff: phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java ---
    @@ -0,0 +1,88 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
    + * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
    + * to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
    + * License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by
    + * applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language
    + * governing permissions and limitations under the License.
    + */
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.mapreduce.util.ConnectionUtil;
    +import org.apache.pig.EvalFunc;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.impl.util.UDFContext;
    +
    +import com.google.common.base.Preconditions;
    +
    +/**
    + * UDF to Reserve a chunk of numbers for a given sequence
    + * 
    + * @note The way this UDF is invoked we open a new connection for every tuple row. The UDF will not perform well on
    --- End diff --
    
    It should be alright, but might be able to be improved. As always, we'll want to perf test this and the rest of the Phoenix/Pig loader integration.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by JamesRTaylor <gi...@git.apache.org>.
Github user JamesRTaylor commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34330100
  
    --- Diff: phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java ---
    @@ -0,0 +1,88 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
    + * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
    + * to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
    + * License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by
    + * applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language
    + * governing permissions and limitations under the License.
    + */
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.mapreduce.util.ConnectionUtil;
    +import org.apache.pig.EvalFunc;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.impl.util.UDFContext;
    +
    +import com.google.common.base.Preconditions;
    +
    +/**
    + * UDF to Reserve a chunk of numbers for a given sequence
    + * 
    + * @note The way this UDF is invoked we open a new connection for every tuple row. The UDF will not perform well on
    + *       large datasets as it involves creating a new connection for every tuple row
    + */
    +public class ReserveNSequence extends EvalFunc<Long> {
    +
    +    public static final String INVALID_TUPLE_MESSAGE = "Tuple should have correct fields(NumtoReserve,SequenceName,zkquorum.";
    +    public static final String EMPTY_SEQUENCE_NAME_MESSAGE = "Sequence name should be not null";
    +    public static final String EMPTY_ZK_MESSAGE = "ZKQuorum should be not null";
    +    public static final String INVALID_NUMBER_MESSAGE = "NUmber of Sequences to Reserve should be greater than 0";
    --- End diff --
    
    Typo: NUmber -> Number


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by siddhimehta <gi...@git.apache.org>.
Github user siddhimehta commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34330210
  
    --- Diff: phoenix-pig/src/it/java/org/apache/phoenix/pig/udf/ReserveNSequenceTestIT.java ---
    @@ -0,0 +1,284 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +import static org.apache.phoenix.query.BaseTest.setUpConfigForMiniCluster;
    +import static org.junit.Assert.assertEquals;
    +import static org.junit.Assert.assertTrue;
    +
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.DriverManager;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +import java.util.Properties;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HBaseTestingUtility;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.end2end.NeedsOwnMiniClusterTest;
    +import org.apache.phoenix.jdbc.PhoenixDriver;
    +import org.apache.phoenix.util.PhoenixRuntime;
    +import org.apache.phoenix.util.PropertiesUtil;
    +import org.apache.phoenix.util.TestUtil;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.data.TupleFactory;
    +import org.apache.pig.impl.util.UDFContext;
    +import org.junit.After;
    +import org.junit.AfterClass;
    +import org.junit.Before;
    +import org.junit.BeforeClass;
    +import org.junit.Rule;
    +import org.junit.Test;
    +import org.junit.experimental.categories.Category;
    +import org.junit.rules.ExpectedException;
    +
    +/**
    + * Test class to run all the Pig Sequence UDF integration tests against a virtual map reduce cluster.
    + */
    +@Category(NeedsOwnMiniClusterTest.class)
    +public class ReserveNSequenceTestIT {
    --- End diff --
    
    @JamesRTaylor  Sounds good.Updating the tests.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by siddhimehta <gi...@git.apache.org>.
Github user siddhimehta commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34329942
  
    --- Diff: phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java ---
    @@ -0,0 +1,88 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
    + * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
    + * to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
    + * License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by
    + * applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language
    + * governing permissions and limitations under the License.
    + */
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.mapreduce.util.ConnectionUtil;
    +import org.apache.pig.EvalFunc;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.impl.util.UDFContext;
    +
    +import com.google.common.base.Preconditions;
    +
    +/**
    + * UDF to Reserve a chunk of numbers for a given sequence
    + * 
    + * @note The way this UDF is invoked we open a new connection for every tuple row. The UDF will not perform well on
    + *       large datasets as it involves creating a new connection for every tuple row
    + */
    +public class ReserveNSequence extends EvalFunc<Long> {
    +
    +    public static final String INVALID_TUPLE_MESSAGE = "Tuple should have correct fields(NumtoReserve,SequenceName,zkquorum.";
    +    public static final String EMPTY_SEQUENCE_NAME_MESSAGE = "Sequence name should be not null";
    +    public static final String EMPTY_ZK_MESSAGE = "ZKQuorum should be not null";
    +    public static final String INVALID_NUMBER_MESSAGE = "NUmber of Sequences to Reserve should be greater than 0";
    +    public static final String SEQUENCE_NAME_CONF_KEY = "phoenix.sequence.name";
    +
    +    /**
    +     * Reserve N next sequences for a sequence name. N is the first field in the tuple. Sequence name is the second
    +     * field in the tuple zkquorum is the third field in the tuple
    +     */
    +    @Override
    +    public Long exec(Tuple input) throws IOException {
    --- End diff --
    
    UDF that taken in tuple with number,sequenceName,ZkEndpoint and bulk reserves the sequence


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by JamesRTaylor <gi...@git.apache.org>.
Github user JamesRTaylor commented on a diff in the pull request:

    https://github.com/apache/phoenix/pull/98#discussion_r34332525
  
    --- Diff: phoenix-pig/src/main/java/org/apache/phoenix/pig/udf/ReserveNSequence.java ---
    @@ -0,0 +1,88 @@
    +/**
    + * 
    + */
    +package org.apache.phoenix.pig.udf;
    +
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE
    + * file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file
    + * to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the
    + * License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by
    + * applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language
    + * governing permissions and limitations under the License.
    + */
    +import java.io.IOException;
    +import java.sql.Connection;
    +import java.sql.ResultSet;
    +import java.sql.SQLException;
    +
    +import org.apache.hadoop.conf.Configuration;
    +import org.apache.hadoop.hbase.HConstants;
    +import org.apache.phoenix.mapreduce.util.ConnectionUtil;
    +import org.apache.pig.EvalFunc;
    +import org.apache.pig.data.Tuple;
    +import org.apache.pig.impl.util.UDFContext;
    +
    +import com.google.common.base.Preconditions;
    +
    +/**
    + * UDF to Reserve a chunk of numbers for a given sequence
    + * 
    + * @note The way this UDF is invoked we open a new connection for every tuple row. The UDF will not perform well on
    --- End diff --
    
    Prashant would know if that's possible, I suspect, but I'm not sure (as you're definitely more of a Pig expert than me). @mravi may know too. It's not too bad from a Phoenix perspective, as we cache the underlying HConnection, so making a new connection (on the same JVM) is cheap.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

[GitHub] phoenix pull request: PHOENIX-2098 - Udf that given a number bulk ...

Posted by siddhimehta <gi...@git.apache.org>.
Github user siddhimehta commented on the pull request:

    https://github.com/apache/phoenix/pull/98#issuecomment-120243946
  
    @JamesRTaylor  Pull request for PHOENIX-2098


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---