Table parameterized functions in database

1. A computer-implemented method, comprising:

providing table parameterized function (TPF) functionality in a database having defined therein a TPF, wherein the definition of the TPF defines one or more parameters of the TPF, at least one of the parameters being a table parameter;

receiving a query that operates to call the TPF to process information from a producer, wherein the query defines one or more input parameters, the input parameters comprising at least one table input parameter to be used as input for calling the TPF, wherein the table parameter comprises a set of rows from a table of the database;

processing the query to produce a result, wherein the processing comprises executing two or more rows of the table input parameter in parallel;

marking data of the table indicated by the table input parameter that is not to be provided to a consumer as unavailable without deleting the data from a memory structure, wherein the marking of the data of the memory structure consumes fewer processing resources compared to removing the data of the table that is not to be provided from the memory structure; and

returning access to the memory structure as the result of the query, wherein the memory structure includes at least a portion of the data that has been marked as being unavailable.

2. The computer-implemented method of claim 1 , wherein returning the result of the query comprises:

rewinding the result to allow the result to be read multiple times.

3. The computer-implemented method of claim 1 , wherein processing the query to produce a result comprises:

transferring a plurality of blocks of row data using a single call from the producer to the consumer.

4. The computer-implemented method of claim 1 , wherein processing the query to produce a result comprises:

using metadata responsive to the result of a query between the producer and the consumer to improve efficiency by placing restrictions on the information from the database that is used to process the query, wherein the restrictions include the marking.

5. The computer-implemented method of claim 1 , wherein processing the query to produce a result comprises:

negotiating ordering properties for the query between the producer and the consumer, wherein the ordering properties include an already specified ordering for a query input table and an appropriate ordering for the query input table; and

processing the query while enforcing the ordering properties by at least one of the producer and the consumer.

6. The computer-implemented method of claim 1 , wherein processing the query to produce a result comprises:

negotiating partitioning properties for the query between the producer and the consumer;

creating separate instances of the table input parameter, each instance comprising a portion of data from the input parameter; and

processing the query in parallel using the separate instances of the table input parameter.

7. The computer-implemented method of claim 1 , wherein processing the query to produce a result comprises:

negotiating clustering properties between the producer and the consumer; and

processing the query based on the negotiated clustering properties.

8. The computer-implemented method of claim 1 , wherein processing the query to produce a result comprises:

allowing the TPF to dynamically support parallelism or distributed processing when processing the query.

9. The computer-implemented method of claim 1 , wherein the set of rows from the table of the database of the table parameter exist within the database prior to the receiving the query.

10. The computer-implemented method of claim 1 , wherein the processing comprises transferring a plurality of blocks of row data from the producer to a consumer without data movement.

11. The computer-implemented method of claim 1 , wherein the query with the table input parameter is an SQL query.

12. The computer-implemented method of claim 1 , wherein results from the parallel execution of the two or more partitions are assembled into the result.

13. The computer-implemented method of claim 1 , wherein the providing comprises:

wherein the definition of the TPF defines two or more parameters of the TPF including both a table parameter and a single-value scalar parameter.

14. The computer-implemented method of claim 13 , wherein the result of processing the query with the table input parameter is a scalar value.

15. The computer-implemented method of claim 1 , wherein the processing is performed without copying the table input parameter.

16. A non-transitory computer-readable device, having instructions stored thereon that when executed by a processor, cause the processor to perform operations comprising:

providing table parameterized function (TPF) functionality in a database having defined therein a TPF, wherein the definition of the TPF defines one or more parameters of the TPF, at least one of the parameters being a table parameter;

receiving a query that operates to call the TPF to process information from a producer, wherein the query defines one or more input parameters, the input parameters comprising at least one table input parameter to be used as input for calling the TPF, wherein the table parameter comprises a set of rows from a table of the database;

processing the query to produce a result, wherein the processing comprises executing two or more rows of the table input parameter in parallel;

marking data of the table indicated by the table input parameter that is not to be provided to a consumer as unavailable without deleting the data from a memory structure, wherein the marking of the data of the memory structure consumes fewer processing resources compared to removing the data of the table that is not to be provided from the memory structure; and

returning access to the memory structure as the result of the query, wherein the memory structure includes at least a portion of the data that has been marked as being unavailable.

17. The non-transitory computer-readable device of claim 16 , wherein returning the result of the query comprises:

rewinding the result to allow the result to be read multiple times.

18. The non-transitory computer-readable device of claim 16 , wherein processing the query to produce a result comprises:

transferring a plurality of blocks of row data using a single call from the producer to the consumer.

19. The non-transitory computer readable device of claim 16 , wherein processing the query to produce a result comprises:

using metadata responsive to the result of a query between the producer and the consumer to improve efficiency by placing restrictions on the information from the database that is used to process the query.

20. The non-transitory computer readable device of claim 16 , wherein processing the query to produce a result comprises:

negotiating ordering properties for the query between the producer and the consumer, wherein the ordering properties include an already specified ordering for a query input table and an appropriate ordering for the query input table; and

processing the query while enforcing the ordering properties by at least one of the producer and the consumer.

21. The non-transitory computer readable device of claim 16 , wherein processing the query to produce a result comprises:

negotiating partitioning properties for the query between the producer and the consumer;

creating separate instances of the table input parameter, each instance comprising a portion of data from the input parameter; and

processing the query in parallel using the separate instances of the table input parameter.

22. The non-transitory computer readable device of claim 16 , wherein processing the query to produce a result comprises:

negotiating clustering properties between the producer and the consumer; and

processing the query based on the negotiated clustering properties.

23. The non-transitory computer readable device of claim 16 , wherein processing the query to produce a result comprises:

allowing the TPF to dynamically support parallelism or distributed processing when processing the query.

24. A system, comprising:

a database, configured to provide table parameterized function (TPF) functionality and having defined therein a TPF, wherein the definition of the TPF defines one or more parameters of the TPF, at least one of the parameters being a table parameter;

a processor configured to:

receive a query that operates to call the TPF to process information from a producer, wherein the query defines one or more input parameters, the input parameters comprising at least one table input parameter to be used as input for calling the TPF, wherein the table parameter comprises a set of rows from a table of the database,

process the query to produce a result, wherein the processing comprises executing two or more rows of the table input parameter in parallel,

mark data of the table indicated by the table input parameter that is not to be provided to a consumer as unavailable without deleting the data from a memory structure, wherein the marking of the data of the memory structure consumes fewer processing resources compared to removing the data of the table that is not to be provided from the memory structure; and

return access to the memory structure as the result of the query, wherein the memory structure includes at least a portion of the data that has been marked as being unavailable.

25. The system of claim 24 , wherein the processor s further configured to rewind the result to allow the result to be read multiple times.