MCPcopy Create free account

hub / github.com/data-integrations/wrangler / functions

Functions1,973 in github.com/data-integrations/wrangler

↓ 2 callersMethodgetPeopleList
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1934
↓ 2 callersMethodgetPhonesList
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:962
↓ 2 callersMethodgetReader
()
wrangler-core/src/main/java/co/cask/wrangler/codec/AbstractAvroDecoder.java:45
↓ 2 callersMethodgetResults
@return Number of results to return in the API.
wrangler-service/src/main/java/co/cask/wrangler/proto/Workspace.java:39
↓ 2 callersMethodgetRows
(int lines, ResultSet result)
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:580
↓ 2 callersMethodgetStatus
@return status of the processing on the backend.
wrangler-core/src/main/java/co/cask/wrangler/clients/Response.java:46
↓ 2 callersMethodgetTables
(Connection connection, String instanceId, String databaseId)
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:414
↓ 2 callersMethodgetUpdated
@return Unix timestamp about when the recipe was updated.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:102
↓ 2 callersMethodgetVersions
(HttpRequest request, HttpResponder responder)
wrangler-core/src/test/java/co/cask/wrangler/clients/SchemaRegistryClientTest.java:140
↓ 2 callersMethodgetVersions
()
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaEntry.java:60
↓ 2 callersMethodgetWeight
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Reservoir.java:126
↓ 2 callersMethodgetWorkspace
@return Workspace specification associated with the request.
wrangler-service/src/main/java/co/cask/wrangler/proto/Request.java:33
↓ 2 callersMethodhasKey
Checks if the key is present in the store. @param id of the key to be checked. @return true if present, false otherwise.
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:239
↓ 2 callersMethodhasProperty
Checks if connection has a property defined or not. @param key to be checked for presence. @return true if present, else false.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:117
↓ 2 callersMethodhasSchema
Checks if schema id and version combination exists in the registry. @param id of the schema to be checked @param version version of the schema to be
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:155
↓ 2 callersMethodhashCode
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1064
↓ 2 callersMethodincrement
Increments a value of the variable. @param name of the variable. @param value associated with the variable.
wrangler-api/src/main/java/co/cask/wrangler/api/TransientStore.java:56
↓ 2 callersMethodinfo
(Object o)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:180
↓ 2 callersMethodinitialize
Initialises the directive with a {@link DirectiveContext}. @param context, instance of context object or null.
wrangler-api/src/main/java/co/cask/wrangler/api/RecipeParser.java:42
↓ 2 callersMethodisDateTime
(List<Map<Pattern, String>> patternGroupList, String value)
wrangler-core/src/main/java/co/cask/wrangler/dq/DateTimePattern.java:108
↓ 2 callersMethodkeysToLower
This function lowers the keys of the json. it applies this transformation recurively. @param element to be transformed. @return modified element.
wrangler-core/src/main/java/co/cask/functions/JSON.java:127
↓ 2 callersMethodlist
Lists the content of the path specified using the {@Location}. @param request HTTP Request Handler @param responder HTTP Response Handler @param path
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/FilesystemExplorer.java:87
↓ 2 callersMethodlistDatasets
List all datasets. @param request HTTP requets handler. @param responder HTTP response handler.
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:135
↓ 2 callersMethodlookup
Looks up the code in the catalog. @param code to be looked up. @return StaticCatalog entry if found, else null.
wrangler-core/src/main/java/co/cask/directives/lookup/StaticCatalog.java:41
↓ 2 callersMethodnextLine
Returns the next line in the wrapped <code>Reader. @return the next line from the input @throws NoSuchElementException if there is no line to return
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/BoundedLineInputStream.java:132
↓ 2 callersMethodoptional
@return true, if this <code>TokenDefinition</code> is optional, false otherwise.
wrangler-api/src/main/java/co/cask/wrangler/api/parser/TokenDefinition.java:78
↓ 2 callersMethodparser
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1807
↓ 2 callersMethodprocess
(List<String> input)
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:389
↓ 2 callersMethodr
(String s)
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:227
↓ 2 callersMethodreadArray
(JsonArray array, String path)
wrangler-core/src/main/java/co/cask/wrangler/utils/JsonPathGenerator.java:98
↓ 2 callersMethodreload
This method reloads the directives from the artifacts into the registry. Any implementation of this method should provide support for deletes, updates
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveRegistry.java:51
↓ 2 callersMethodrequest
(URL url, String method, Type classz)
wrangler-core/src/main/java/co/cask/wrangler/clients/SchemaRegistryClient.java:214
↓ 2 callersMethodsamplingProcess
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Poisson.java:136
↓ 2 callersMethodscope
()
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveInfo.java:84
↓ 2 callersMethodsetCreated
Sets the time of when the recipe was created. @param created unix timestamp of when recipe was created.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:95
↓ 2 callersMethodsetDescription
Sets the recipe description. @param description for the recipe.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:162
↓ 2 callersMethodsetField
( com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1260
↓ 2 callersMethodsetId
<pre> Unique ID number for this person. </pre> <code>int32 id = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1445
↓ 2 callersMethodsetName
Sets the display name of the directive. @param name to be displayed for the directive.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:146
↓ 2 callersMethodsetRepeatedField
( com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1273
↓ 2 callersMethodsetType
Sets the type of the connection. @param type of the connection to be set.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:144
↓ 2 callersMethodsetto
(String s)
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:218
↓ 2 callersMethodstart
(Message message)
wrangler-core/src/main/java/co/cask/directives/parser/HL7Parser.java:144
↓ 2 callersMethodtoJsonBytes
Converts object of type T to byte array. @param object to be converted @return byte array representing JSON.
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:97
↓ 2 callersMethodtoJsonBytes
(Map<String, String> properties)
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:418
↓ 2 callersMethodtoJsonString
Converts a {@link StructuredRecord} to a json string.
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:90
↓ 2 callersMethodtoList
()
wrangler-test/src/main/java/co/cask/wrangler/test/api/TestRows.java:38
↓ 2 callersMethodtoLong
Converts a String value to Long. @param value of type string to be converted to float. @return float value of the string passed.
wrangler-core/src/main/java/co/cask/functions/Global.java:54
↓ 2 callersMethodtransform
(StructuredRecord record, Schema schema)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordConverter.java:36
↓ 2 callersMethodupdate
Updates the already existing object in the object store. @param id of the object to be updated. @param object itself to be updated.
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:283
↓ 2 callersMethodupdateWorkspace
(String id, byte[] key, byte[] data)
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:294
↓ 2 callersMethodvalidateConnection
(String connectionId, Connection connection, HttpServiceResponder responder)
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Service.java:125
↓ 2 callersMethodvalue
()
wrangler-api/src/main/java/co/cask/wrangler/api/parser/ColumnNameList.java:39
↓ 2 callersMethodverify
(Class<? extends Directive> directive)
wrangler-test/src/main/java/co/cask/wrangler/test/TestingRig.java:80
↓ 2 callersMethodvisit
(Primitive primitive, Location location)
wrangler-core/src/main/java/co/cask/directives/parser/HL7Parser.java:213
↓ 2 callersMethodvowelinstem
()
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:179
↓ 1 callersMethodacquire
()
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/DatasetProvider.java:25
↓ 1 callersMethodadd
Adds a {@link ErrorRecord} to the error collector. @param record
wrangler-core/src/main/java/co/cask/wrangler/executor/ErrorRecordCollector.java:56
↓ 1 callersMethodaddDefaultDirectives
Loads all the default system directives that are available with the system.
wrangler-core/src/main/java/co/cask/wrangler/parser/UsageRegistry.java:144
↓ 1 callersMethodaddDirectory
(List<String> dirs)
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Service.java:529
↓ 1 callersMethodaddLoadableDirective
A Recipe can specify the pragma instructions for loading the directives dynamically. This method allows adding the new directive to be loaded as it's
wrangler-api/src/main/java/co/cask/wrangler/api/RecipeSymbol.java:218
↓ 1 callersMethodaddLoadablePragmaDirectives
Automatically adds a load-directives pragma to the list of directives.
wrangler-service/src/main/java/co/cask/wrangler/service/directive/DirectivesService.java:680
↓ 1 callersMethodaddObject
(List<S3ObjectSummary> summaries)
wrangler-service/src/main/java/co/cask/wrangler/service/s3/S3Service.java:500
↓ 1 callersMethodaddOrSetAtIndex
Adds or sets the value to the beginning. @param index at which the column need to be inserted. @param name of the field to be either set or added to
wrangler-api/src/main/java/co/cask/wrangler/api/Row.java:214
↓ 1 callersMethodaddPeople
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:2353
↓ 1 callersMethodaddPhones
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1610
↓ 1 callersMethodaddUsage
Adds a class that extends from <code>AbstractDirective</code> to usage registry. @param classz representing an AbstractDirective</code> implementatio
wrangler-core/src/main/java/co/cask/wrangler/parser/UsageRegistry.java:91
↓ 1 callersMethodaddVersion
Recipe can specify the version of the grammar. This method allows one to extract and add the version to the <code>RecipeSymbol.</code> @param version
wrangler-api/src/main/java/co/cask/wrangler/api/RecipeSymbol.java:207
↓ 1 callersMethodbitMix
Bit-mixing for pseudo-randomization of integers (e.g., to guard against bad hash functions). Implementation is from Murmur's 32 bit finalizer. @param
wrangler-core/src/main/java/co/cask/wrangler/sampling/MathUtils.java:191
↓ 1 callersMethodcall
()
wrangler-core/src/main/java/co/cask/directives/parser/ParseAvro.java:119
↓ 1 callersMethodcall
()
wrangler-core/src/main/java/co/cask/directives/parser/ParseProtobuf.java:111
↓ 1 callersMethodcheckIfRowIsEmpty
(org.apache.poi.ss.usermodel.Row row)
wrangler-core/src/main/java/co/cask/directives/parser/ParseExcel.java:210
↓ 1 callersMethodcheckSchema
(Schema schema, String name)
wrangler-transform/src/main/java/co/cask/wrangler/Wrangler.java:264
↓ 1 callersMethodcolumnName
(int number)
wrangler-core/src/main/java/co/cask/directives/parser/ParseExcel.java:226
↓ 1 callersMethodcolumns
Given a row, finds the length of the row. @param row length needs to be determined. @return length of the row.
wrangler-core/src/main/java/co/cask/functions/DataQuality.java:41
↓ 1 callersMethodcompareTo
(IntermediateSample<T> other)
wrangler-core/src/main/java/co/cask/wrangler/sampling/Reservoir.java:134
↓ 1 callersMethodconfigure
Configures a catalog. @return true if success in configuring, false otherwise.
wrangler-core/src/main/java/co/cask/directives/lookup/StaticCatalog.java:33
↓ 1 callersMethodconvertArray
(Object values, Schema elementSchema)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordConverter.java:71
↓ 1 callersMethodconvertKey
(String key, Schema.Type type)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:218
↓ 1 callersMethodconvertMap
(Map<Object, Object> map, Schema keySchema, Schema valueSchema)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordConverter.java:89
↓ 1 callersMethodconvertResultSetToRow
(ResultSet resultSet)
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:333
↓ 1 callersMethodconvertType
(String toType, Object object)
wrangler-core/src/main/java/co/cask/directives/column/SetType.java:91
↓ 1 callersMethodconvertUnion
(Object value, List<Schema> schemas)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordConverter.java:49
↓ 1 callersMethodcreate
Creates an instance of the object of type T in the store. If the object already exits in the store, which is determined by looking at the key, then an
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:275
↓ 1 callersMethodcreate
Creates an entry in the schema registry. @param id of the schema. @param name of the schema. @param description for the schema.
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:59
↓ 1 callersMethodcreate
Creates a connection object in the connections store. Following is the JSON request for setting the connection. { "name" : "MySQL Production DB",
wrangler-service/src/main/java/co/cask/wrangler/service/connections/ConnectionService.java:147
↓ 1 callersMethodcreate
Creates an entry for Schema with id, name, description and type of schema. if the 'id' already exists, then it overwrites the data with new informatio
wrangler-service/src/main/java/co/cask/wrangler/service/schema/SchemaRegistryService.java:91
↓ 1 callersMethodcreateTestTables
(Connection conn)
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:194
↓ 1 callersMethodcreateTestUser
(Connection conn)
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:188
↓ 1 callersMethodcreateTokenGroup
<code>TokenGroup</code> is created for each directive in the recipe. This method creates a new <code>TokenGroup</code> by passing the <code>SourceInfo
wrangler-api/src/main/java/co/cask/wrangler/api/RecipeSymbol.java:185
↓ 1 callersMethodcreateUberRecord
(List<Row> rows)
wrangler-core/src/test/java/co/cask/wrangler/utils/RecordConvertorTest.java:95
↓ 1 callersMethodcreateUberRecord
Creates a uber record after iterating through all rows. @param rows list of all rows. @return A single record will rows merged across all columns.
wrangler-service/src/main/java/co/cask/wrangler/service/directive/DirectivesService.java:1147
↓ 1 callersMethoddecode
Decodes byte array of binary encoded AVRO into list of {@link Row}. This method will iterate through each of the AVRO schema fields and translate them
wrangler-core/src/main/java/co/cask/wrangler/codec/BinaryAvroDecoder.java:58
↓ 1 callersMethoddecode
(byte[] bytes)
wrangler-core/src/main/java/co/cask/wrangler/codec/ProtobufDecoderUsingDescriptor.java:50
↓ 1 callersMethoddecodeMap
(String name, Map<Object, Object> object, Schema key, Schema value)
wrangler-core/src/main/java/co/cask/wrangler/utils/RecordConvertor.java:360
↓ 1 callersMethoddecodeMessage
(Message message, Row row, String root)
wrangler-core/src/main/java/co/cask/wrangler/codec/ProtobufDecoderUsingDescriptor.java:64
↓ 1 callersMethoddecodeSimpleTypes
(String name, Object object, Schema schema)
wrangler-core/src/main/java/co/cask/wrangler/utils/RecordConvertor.java:197
↓ 1 callersMethoddecodeUnion
(String name, Object object, List<Schema> schemas)
wrangler-core/src/main/java/co/cask/wrangler/utils/RecordConvertor.java:370
↓ 1 callersMethoddefinition
()
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveInfo.java:98
↓ 1 callersMethodderegisterAllDrivers
De-register all SQL drivers that are associated with the class
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:728
← previousnext →301–400 of 1,973, ranked by callers