小编Tak*_* Lê的帖子

我需要从Spark一个DataFrame写入大约100万行到MySQL但是插入太慢了.我怎样才能改进它？

代码如下:

df = sqlContext.createDataFrame(rdd, schema)
df.write.jdbc(url='xx', table='xx', mode='overwrite')

我的应用程序在大多数设备上运行良好，但在某些根设备上运行良好。在onActivityCreated片段中，getActivity保持返回 null。我需要Context类来设置下面的内容。

所以有人可以帮助我吗？

更新

public class BaseProductFragment extends Fragment {

...

public View onCreateView(LayoutInflater inflater, ViewGroup container,
        Bundle savedInstanceState) {
    View rootView = inflater.inflate(layout_id, container,
            false);
    return rootView;
}

public void onActivityCreated(final Bundle savedInstanceState) {
    super.onActivityCreated(savedInstanceState);
    ImageCacheParams cacheParams = new ImageCacheParams(getActivity(),
            Utils.PRODUCTS_CACHE_DIR);
    ....
}