小编shr*_*e11的帖子

Json转换为avro

我正在将Json转换为avro.我有json数据 JSONArray.因此,在将其转换为字节数组时,我面临着问题.

下面是我的代码:

static byte [] fromJsonToAvro(JSONArray json, String schemastr) throws Exception {

ExcelToJson ejj = new ExcelToJson();
List<String> list = new ArrayList<String>();


if (json != null) { 
    int len = json.length();
    for (int i=0;i<len;i++){ 
        list.add(json.get(i).toString());
    } 
}


InputStream input = new ByteArrayInputStream(list.getBytes()); //json.toString().getBytes()

 DataInputStream din = new DataInputStream(input); 
                  .
                  . 
                  .//rest of the logic
Run Code Online (Sandbox Code Playgroud)

那我该怎么办呢?如何将JsonArray对象转换为字节(即,如何对JsonArray对象使用getBytes()方法).上面的代码给出了一个错误,list.getBytes()并说getBytes()是列表的未定义.

java json avro

8
推荐指数
2
解决办法
3万
查看次数

Neo4j服务器与嵌入式模式

我想知道neo4j服务器和嵌入式模式究竟是什么意思.即使我经历了Neo4j Server vs. Embedded之后的事情.但我明白这些概念.我在windows 64bit机器上安装了neo4j 2.1.1,这是一台neo4j服务器.那么当neo4j嵌入模式进入画面时?

另外,我们如何在嵌入模式和服务器模式之间切换,反之亦然?

当我使用mysql进行neo4j迁移(使用批量导入)时,将节点和关系导入neo4j后,在messages.log文件中获取消息,如下所示:

Clean shutdown on BatchInserter(EmbeddedBatchInserter[C:\Users\Neo4j\t2.db]) 
Run Code Online (Sandbox Code Playgroud)

如果我安装了neo4j服务器,嵌入式如何出现在这里?所以请澄清这些问题.

谢谢

neo4j

6
推荐指数
1
解决办法
4464
查看次数

将 xml 数据加载到 hive 表中:org.apache.hadoop.hive.ql.metadata.HiveException

我正在尝试将 XML 数据加载到 Hive 中,但出现错误:

java.lang.RuntimeException: org.apache.hadoop.hive.ql.metadata.HiveException: Hive Runtime Error while processing row {"xmldata":""}

我使用的 xml 文件是:

<?xml version="1.0" encoding="UTF-8"?>
<catalog>
<book>
  <id>11</id>
  <genre>Computer</genre>
  <price>44</price>
</book>
<book>
  <id>44</id>
  <genre>Fantasy</genre>
  <price>5</price>
</book>
</catalog>
Run Code Online (Sandbox Code Playgroud)

我使用的配置单元查询是:

1) Create TABLE xmltable(xmldata string) STORED AS TEXTFILE;
LOAD DATA lOCAL INPATH '/home/user/xmlfile.xml' OVERWRITE INTO TABLE xmltable;

2) CREATE VIEW xmlview (id,genre,price)
AS SELECT
xpath(xmldata, '/catalog[1]/book[1]/id'),
xpath(xmldata, '/catalog[1]/book[1]/genre'),
xpath(xmldata, '/catalog[1]/book[1]/price')
FROM xmltable;

3) CREATE TABLE xmlfinal AS SELECT * FROM xmlview;

4) SELECT * FROM xmlfinal WHERE …
Run Code Online (Sandbox Code Playgroud)

hive xmldataset

5
推荐指数
1
解决办法
2万
查看次数

如何将 XML 文件读取/加载到 neo4j 数据库中

我想为 XML 数据文件创建节点和关系。在neo4j中可以做到吗?

neo4j 是否读取 XML 文件来创建节点和关系?如果是,我怎样才能实现它?

如何将XML文件加载到neo4j数据库中?

谢谢

xml neo4j

5
推荐指数
1
解决办法
8268
查看次数

neo4j图数据库中的元数据

我知道Neo4j以图表而不是表格的形式存储结构化数据。在RDBMS中,我们将拥有表的模式,但在Neo4j中,我们不会拥有表。仅定义节点、关系和属性。那么neo4jmetadata中有没有什么概念呢?比如数据库中是否存储了有关节点、关系的信息?如果是,它如何以及在元数据中存储什么?另外我们在图数据库中哪里可以找到元数据相关信息(位置)

谢谢,

neo4j

3
推荐指数
1
解决办法
5377
查看次数

在 neo4j 中为单个属性设置多个值

我正在使用 neo4j 2.1.2 社区版。

我的查询,我可以为单个属性添加多个值吗?

例如,假设我有一个名为“11”的节点。11 具有名为 name - john, age-34, sex -m, phone_no- 1234,5678 的属性。所以它有两个 phone_no 值。那么我如何创建一个具有属性名称、年龄、性别和电话号码的节点,其中电话号码有 2 个值。

通常会这样做(对于单个电话号码),

CREATE (n:Person{name:'john',age:34,gender:'m', phone_no:1234})
Run Code Online (Sandbox Code Playgroud)

因此,对于多个电话号码,我可以执行以下操作:

CREATE (n:Person{name:'john',age:34,gender:'m', phone_no:1234,5678})
Run Code Online (Sandbox Code Playgroud)

那么我如何使用密码查询来实现它呢?

谢谢

neo4j cypher

1
推荐指数
1
解决办法
3322
查看次数

Neo4j 2.0.4支持"LOAD CSV FROM"命令

我目前正在使用neo4j 2.0.4版本.早些时候我使用的是neo4j 2.1.2版本.我将neo4j版本从2.1.2降级到2.0.4,因为我无法使用批量导入将数据从MySQL导入到neo4j.

现在我正在使用Neo4j 2.0.4.当我试图使用like将csv文件加载到noe4j时LOAD CSV FROM "file:D:\\Neo4\\try.csv" AS emp ...,它会抛出如下错误

Invalid input 'L': expected <init> (line 1, column 1)
"LOAD CSV FROM "file:D:\\Neo4\\try.csv" AS emp"
Run Code Online (Sandbox Code Playgroud)

当我使用neo4j 2.1.2尝试相同的查询时,它运行正常并显示正确的图形.

那么2.0.4不支持LOAD CSV FROM 命令吗?在2.0.4中需要做些什么来获得正确的输出而没有错误?

谢谢

neo4j cypher

0
推荐指数
1
解决办法
212
查看次数

标签 统计

neo4j ×5

cypher ×2

avro ×1

hive ×1

java ×1

json ×1

xml ×1

xmldataset ×1